[INFO] cloning repository https://github.com/killuazoldyck680/redis-clone
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/killuazoldyck680/redis-clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fkilluazoldyck680%2Fredis-clone", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fkilluazoldyck680%2Fredis-clone'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] ac88ff5c3735f3b644b3504e0ad53897a422de3a
[INFO] checking killuazoldyck680/redis-clone against 40527f3e444fde1deb361751bdef9b9e11d1b971+rustflags=--cfg crater_hack --force-warn invalid-c-variadic-arguments for pr-162478
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fkilluazoldyck680%2Fredis-clone" "/workspace/builds/worker-6-tc2/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-6-tc2/source'...
[INFO] [stderr] done.
[INFO] started tweaking git repo https://github.com/killuazoldyck680/redis-clone
[INFO] finished tweaking git repo https://github.com/killuazoldyck680/redis-clone
[INFO] tweaked toml for git repo https://github.com/killuazoldyck680/redis-clone written to /workspace/builds/worker-6-tc2/source/Cargo.toml
[INFO] validating manifest of git repo https://github.com/killuazoldyck680/redis-clone on toolchain 40527f3e444fde1deb361751bdef9b9e11d1b971
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+40527f3e444fde1deb361751bdef9b9e11d1b971" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] crate git repo https://github.com/killuazoldyck680/redis-clone already has a lockfile, it will not be regenerated
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+40527f3e444fde1deb361751bdef9b9e11d1b971" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-6-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-m" "1610612736" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:8683fc1fc2eb5c9ac98e0d076ab094b2ffac7f99da555d2b6a2e27f346de2ec7" "sleep" "infinity", kill_on_drop: false }`
[INFO] [stdout] a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2
[INFO] running `Command { std: "docker" "start" "a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-w" "/opt/rustwide/workdir" "--user" "0:0" "a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2" "/opt/rustwide/cargo-home/bin/cargo" "+40527f3e444fde1deb361751bdef9b9e11d1b971" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "exec" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid --cfg crater_hack --force-warn invalid-c-variadic-arguments" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-w" "/opt/rustwide/workdir" "--user" "0:0" "a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2" "/opt/rustwide/cargo-home/bin/cargo" "+40527f3e444fde1deb361751bdef9b9e11d1b971" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stderr]     Checking smallvec v1.15.2
[INFO] [stderr]    Compiling anyhow v1.0.103
[INFO] [stderr]     Checking bytes v1.12.0
[INFO] [stderr]    Compiling syn v2.0.118
[INFO] [stderr]     Checking parking_lot_core v0.9.12
[INFO] [stderr]     Checking parking_lot v0.12.5
[INFO] [stderr]    Compiling tokio-macros v2.7.0
[INFO] [stderr]     Checking tokio v1.52.3
[INFO] [stderr]     Checking redis-clone v0.1.0 (/opt/rustwide/workdir)
[INFO] [stdout] error[E0425]: cannot find value `sub_registry` in this scope
[INFO] [stdout]    --> src/main.rs:569:42
[INFO] [stdout]     |
[INFO] [stdout] 569 |     let sub_registry_clone = Arc::clone(&sub_registry);
[INFO] [stdout]     |                                          ^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: a local variable with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 569 -     let sub_registry_clone = Arc::clone(&sub_registry);
[INFO] [stdout] 569 +     let sub_registry_clone = Arc::clone(&sub_regsitry);
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `sub_registry` in this scope
[INFO] [stdout]     --> src/main.rs:1744:32
[INFO] [stdout]      |
[INFO] [stdout] 1744 |             let mut registry = sub_registry.lock().unwrap();
[INFO] [stdout]      |                                ^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]      |
[INFO] [stdout] help: a local variable with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1744 -             let mut registry = sub_registry.lock().unwrap();
[INFO] [stdout] 1744 +             let mut registry = sub_regsitry.lock().unwrap();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `tx` in this scope
[INFO] [stdout]     --> src/main.rs:1748:19
[INFO] [stdout]      |
[INFO] [stdout] 1748 |             .push(tx.clone());
[INFO] [stdout]      |                   ^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `sub_registry` in this scope
[INFO] [stdout]    --> src/main.rs:569:42
[INFO] [stdout]     |
[INFO] [stdout] 569 |     let sub_registry_clone = Arc::clone(&sub_registry);
[INFO] [stdout]     |                                          ^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]     |
[INFO] [stdout] help: a local variable with a similar name exists
[INFO] [stdout]     |
[INFO] [stdout] 569 -     let sub_registry_clone = Arc::clone(&sub_registry);
[INFO] [stdout] 569 +     let sub_registry_clone = Arc::clone(&sub_regsitry);
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::env::args`
[INFO] [stdout]  --> src/main.rs:2:5
[INFO] [stdout]   |
[INFO] [stdout] 2 | use std::env::args;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::fmt::format`
[INFO] [stdout]  --> src/main.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::fmt::format;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `sub_registry` in this scope
[INFO] [stdout]     --> src/main.rs:1744:32
[INFO] [stdout]      |
[INFO] [stdout] 1744 |             let mut registry = sub_registry.lock().unwrap();
[INFO] [stdout]      |                                ^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]      |
[INFO] [stdout] help: a local variable with a similar name exists
[INFO] [stdout]      |
[INFO] [stdout] 1744 -             let mut registry = sub_registry.lock().unwrap();
[INFO] [stdout] 1744 +             let mut registry = sub_regsitry.lock().unwrap();
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0425]: cannot find value `tx` in this scope
[INFO] [stdout]     --> src/main.rs:1748:19
[INFO] [stdout]      |
[INFO] [stdout] 1748 |             .push(tx.clone());
[INFO] [stdout]      |                   ^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `create_dir`
[INFO] [stdout]  --> src/main.rs:4:21
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::fs::{File, create_dir};
[INFO] [stdout]   |                     ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::env::args`
[INFO] [stdout]  --> src/main.rs:2:5
[INFO] [stdout]   |
[INFO] [stdout] 2 | use std::env::args;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::fmt::format`
[INFO] [stdout]  --> src/main.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use std::fmt::format;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `env`, `result`, and `string`
[INFO] [stdout]   --> src/main.rs:10:11
[INFO] [stdout]    |
[INFO] [stdout] 10 | use std::{env, result, string, usize, vec};
[INFO] [stdout]    |           ^^^  ^^^^^^  ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `create_dir`
[INFO] [stdout]  --> src/main.rs:4:21
[INFO] [stdout]   |
[INFO] [stdout] 4 | use std::fs::{File, create_dir};
[INFO] [stdout]   |                     ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::tcp::OwnedWriteHalf`
[INFO] [stdout]   --> src/main.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | use tokio::net::tcp::OwnedWriteHalf;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `env`, `result`, and `string`
[INFO] [stdout]   --> src/main.rs:10:11
[INFO] [stdout]    |
[INFO] [stdout] 10 | use std::{env, result, string, usize, vec};
[INFO] [stdout]    |           ^^^  ^^^^^^  ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::tcp::OwnedWriteHalf`
[INFO] [stdout]   --> src/main.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 | use tokio::net::tcp::OwnedWriteHalf;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `bytes::BytesMut`
[INFO] [stdout]   --> src/main.rs:15:5
[INFO] [stdout]    |
[INFO] [stdout] 15 | use bytes::BytesMut;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::stream`
[INFO] [stdout]   --> src/main.rs:22:5
[INFO] [stdout]    |
[INFO] [stdout] 22 | use tokio::stream;
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `bytes::BytesMut`
[INFO] [stdout]   --> src/main.rs:15:5
[INFO] [stdout]    |
[INFO] [stdout] 15 | use bytes::BytesMut;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::stream`
[INFO] [stdout]   --> src/main.rs:22:5
[INFO] [stdout]    |
[INFO] [stdout] 22 | use tokio::stream;
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::DataType::Str`
[INFO] [stdout]   --> src/main.rs:24:5
[INFO] [stdout]    |
[INFO] [stdout] 24 | use crate::DataType::Str;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::DataType::Str`
[INFO] [stdout]   --> src/main.rs:24:5
[INFO] [stdout]    |
[INFO] [stdout] 24 | use crate::DataType::Str;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tcp::OwnedReadHalf`
[INFO] [stdout]  --> src/resp.rs:4:57
[INFO] [stdout]   |
[INFO] [stdout] 4 |     io::{AsyncReadExt, AsyncWriteExt}, net::{TcpStream, tcp::OwnedReadHalf},
[INFO] [stdout]   |                                                         ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tcp::OwnedReadHalf`
[INFO] [stdout]  --> src/resp.rs:4:57
[INFO] [stdout]   |
[INFO] [stdout] 4 |     io::{AsyncReadExt, AsyncWriteExt}, net::{TcpStream, tcp::OwnedReadHalf},
[INFO] [stdout]   |                                                         ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::io::Write`
[INFO] [stdout]    --> src/main.rs:629:6
[INFO] [stdout]     |
[INFO] [stdout] 629 |  use std::io::Write; // <--- MUST BE IMPORTED
[INFO] [stdout]     |      ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::io::Write`
[INFO] [stdout]    --> src/main.rs:629:6
[INFO] [stdout]     |
[INFO] [stdout] 629 |  use std::io::Write; // <--- MUST BE IMPORTED
[INFO] [stdout]     |      ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io::AsyncWriteExt`
[INFO] [stdout]     --> src/main.rs:1532:9
[INFO] [stdout]      |
[INFO] [stdout] 1532 |     use tokio::io::AsyncWriteExt;
[INFO] [stdout]      |         ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io::AsyncWriteExt`
[INFO] [stdout]     --> src/main.rs:1532:9
[INFO] [stdout]      |
[INFO] [stdout] 1532 |     use tokio::io::AsyncWriteExt;
[INFO] [stdout]      |         ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: use of deprecated module `std::usize`: all constants in this module replaced by associated constants on the type
[INFO] [stdout]   --> src/main.rs:10:32
[INFO] [stdout]    |
[INFO] [stdout] 10 | use std::{env, result, string, usize, vec};
[INFO] [stdout]    |                                ^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(deprecated)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: use of deprecated module `std::usize`: all constants in this module replaced by associated constants on the type
[INFO] [stdout]   --> src/main.rs:10:32
[INFO] [stdout]    |
[INFO] [stdout] 10 | use std::{env, result, string, usize, vec};
[INFO] [stdout]    |                                ^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(deprecated)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]     --> src/main.rs:1733:65
[INFO] [stdout]      |
[INFO] [stdout] 1733 |             Value::BulkString(bytes) => String::from_utf8_lossy(&bytes).to_string(),
[INFO] [stdout]      |                                         ----------------------- ^^^^^^ expected `&[u8]`, found `&String`
[INFO] [stdout]      |                                         |
[INFO] [stdout]      |                                         arguments to this function are incorrect
[INFO] [stdout]      |
[INFO] [stdout]      = note: expected reference `&[u8]`
[INFO] [stdout]                 found reference `&String`
[INFO] [stdout] note: associated function defined here
[INFO] [stdout]     --> /rustc/40527f3e444fde1deb361751bdef9b9e11d1b971/library/alloc/src/string.rs:628:11
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]     --> src/main.rs:1733:65
[INFO] [stdout]      |
[INFO] [stdout] 1733 |             Value::BulkString(bytes) => String::from_utf8_lossy(&bytes).to_string(),
[INFO] [stdout]      |                                         ----------------------- ^^^^^^ expected `&[u8]`, found `&String`
[INFO] [stdout]      |                                         |
[INFO] [stdout]      |                                         arguments to this function are incorrect
[INFO] [stdout]      |
[INFO] [stdout]      = note: expected reference `&[u8]`
[INFO] [stdout]                 found reference `&String`
[INFO] [stdout] note: associated function defined here
[INFO] [stdout]     --> /rustc/40527f3e444fde1deb361751bdef9b9e11d1b971/library/alloc/src/string.rs:628:11
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `encode` found for enum `Value` in the current scope
[INFO] [stdout]     --> src/main.rs:1757:32
[INFO] [stdout]      |
[INFO] [stdout] 1757 |         let payload = response.encode();
[INFO] [stdout]      |                                ^^^^^^ method not found in `Value`
[INFO] [stdout]      |
[INFO] [stdout]     ::: src/resp.rs:8:1
[INFO] [stdout]      |
[INFO] [stdout]    8 | pub enum Value {
[INFO] [stdout]      | -------------- method `encode` not found for this enum
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no method named `encode` found for enum `Value` in the current scope
[INFO] [stdout]     --> src/main.rs:1757:32
[INFO] [stdout]      |
[INFO] [stdout] 1757 |         let payload = response.encode();
[INFO] [stdout]      |                                ^^^^^^ method not found in `Value`
[INFO] [stdout]      |
[INFO] [stdout]     ::: src/resp.rs:8:1
[INFO] [stdout]      |
[INFO] [stdout]    8 | pub enum Value {
[INFO] [stdout]      | -------------- method `encode` not found for this enum
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: the method `write_all` exists for reference `&Arc<std::sync::Mutex<tokio::net::TcpStream>>`, but its trait bounds were not satisfied
[INFO] [stdout]     --> src/main.rs:1758:20
[INFO] [stdout]      |
[INFO] [stdout] 1758 |         write_half.write_all(&payload).await?;
[INFO] [stdout]      |                    ^^^^^^^^^ method cannot be called on `&Arc<std::sync::Mutex<tokio::net::TcpStream>>` due to unsatisfied trait bounds
[INFO] [stdout]      |
[INFO] [stdout]      = note: the following trait bounds were not satisfied:
[INFO] [stdout]              `&Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWrite`
[INFO] [stdout]              which is required by `&Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWriteExt`
[INFO] [stdout]              `Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWrite`
[INFO] [stdout]              which is required by `Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWriteExt`
[INFO] [stdout]              `std::sync::Mutex<tokio::net::TcpStream>: std::io::Write`
[INFO] [stdout]              which is required by `Arc<std::sync::Mutex<tokio::net::TcpStream>>: std::io::Write`
[INFO] [stdout]              `std::sync::Mutex<tokio::net::TcpStream>: AsyncWrite`
[INFO] [stdout]              which is required by `std::sync::Mutex<tokio::net::TcpStream>: AsyncWriteExt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: the method `write_all` exists for reference `&Arc<std::sync::Mutex<tokio::net::TcpStream>>`, but its trait bounds were not satisfied
[INFO] [stdout]     --> src/main.rs:1758:20
[INFO] [stdout]      |
[INFO] [stdout] 1758 |         write_half.write_all(&payload).await?;
[INFO] [stdout]      |                    ^^^^^^^^^ method cannot be called on `&Arc<std::sync::Mutex<tokio::net::TcpStream>>` due to unsatisfied trait bounds
[INFO] [stdout]      |
[INFO] [stdout]      = note: the following trait bounds were not satisfied:
[INFO] [stdout]              `&Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWrite`
[INFO] [stdout]              which is required by `&Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWriteExt`
[INFO] [stdout]              `Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWrite`
[INFO] [stdout]              which is required by `Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWriteExt`
[INFO] [stdout]              `std::sync::Mutex<tokio::net::TcpStream>: std::io::Write`
[INFO] [stdout]              which is required by `Arc<std::sync::Mutex<tokio::net::TcpStream>>: std::io::Write`
[INFO] [stdout]              `std::sync::Mutex<tokio::net::TcpStream>: AsyncWrite`
[INFO] [stdout]              which is required by `std::sync::Mutex<tokio::net::TcpStream>: AsyncWriteExt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0277]: the `?` operator can only be used in an async function that returns `Result` or `Option` (or another type that implements `FromResidual`)
[INFO] [stdout]     --> src/main.rs:1758:45
[INFO] [stdout]      |
[INFO] [stdout]  566 |   async fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,local_subscriptions: &mut HashSet<String>) -> Value {
[INFO] [stdout]      |  _______________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________-
[INFO] [stdout]  567 | |     let master_replid = "8371b4fb1155b71f4a04d3e1bc3e18c4a990aeeb";
[INFO] [stdout]  568 | |
[INFO] [stdout]  569 | |     let sub_registry_clone = Arc::clone(&sub_registry);
[INFO] [stdout] ...    |
[INFO] [stdout] 1758 | |         write_half.write_all(&payload).await?;
[INFO] [stdout]      | |                                             ^ cannot use the `?` operator in an async function that returns `Value`
[INFO] [stdout] ...    |
[INFO] [stdout] 1771 | | }
[INFO] [stdout]      | |_- this function should return `Result` or `Option` to accept `?`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0277]: the `?` operator can only be used in an async function that returns `Result` or `Option` (or another type that implements `FromResidual`)
[INFO] [stdout]     --> src/main.rs:1758:45
[INFO] [stdout]      |
[INFO] [stdout]  566 |   async fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,local_subscriptions: &mut HashSet<String>) -> Value {
[INFO] [stdout]      |  _______________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________-
[INFO] [stdout]  567 | |     let master_replid = "8371b4fb1155b71f4a04d3e1bc3e18c4a990aeeb";
[INFO] [stdout]  568 | |
[INFO] [stdout]  569 | |     let sub_registry_clone = Arc::clone(&sub_registry);
[INFO] [stdout] ...    |
[INFO] [stdout] 1758 | |         write_half.write_all(&payload).await?;
[INFO] [stdout]      | |                                             ^ cannot use the `?` operator in an async function that returns `Value`
[INFO] [stdout] ...    |
[INFO] [stdout] 1771 | | }
[INFO] [stdout]      | |_- this function should return `Result` or `Option` to accept `?`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: the method `flush` exists for reference `&Arc<std::sync::Mutex<tokio::net::TcpStream>>`, but its trait bounds were not satisfied
[INFO] [stdout]     --> src/main.rs:1759:20
[INFO] [stdout]      |
[INFO] [stdout] 1759 |         write_half.flush().await?;
[INFO] [stdout]      |                    ^^^^^ method cannot be called on `&Arc<std::sync::Mutex<tokio::net::TcpStream>>` due to unsatisfied trait bounds
[INFO] [stdout]      |
[INFO] [stdout]      = note: the following trait bounds were not satisfied:
[INFO] [stdout]              `&Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWrite`
[INFO] [stdout]              which is required by `&Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWriteExt`
[INFO] [stdout]              `Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWrite`
[INFO] [stdout]              which is required by `Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWriteExt`
[INFO] [stdout]              `std::sync::Mutex<tokio::net::TcpStream>: std::io::Write`
[INFO] [stdout]              which is required by `Arc<std::sync::Mutex<tokio::net::TcpStream>>: std::io::Write`
[INFO] [stdout]              `std::sync::Mutex<tokio::net::TcpStream>: AsyncWrite`
[INFO] [stdout]              which is required by `std::sync::Mutex<tokio::net::TcpStream>: AsyncWriteExt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: the method `flush` exists for reference `&Arc<std::sync::Mutex<tokio::net::TcpStream>>`, but its trait bounds were not satisfied
[INFO] [stdout]     --> src/main.rs:1759:20
[INFO] [stdout]      |
[INFO] [stdout] 1759 |         write_half.flush().await?;
[INFO] [stdout]      |                    ^^^^^ method cannot be called on `&Arc<std::sync::Mutex<tokio::net::TcpStream>>` due to unsatisfied trait bounds
[INFO] [stdout]      |
[INFO] [stdout]      = note: the following trait bounds were not satisfied:
[INFO] [stdout]              `&Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWrite`
[INFO] [stdout]              which is required by `&Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWriteExt`
[INFO] [stdout]              `Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWrite`
[INFO] [stdout]              which is required by `Arc<std::sync::Mutex<tokio::net::TcpStream>>: AsyncWriteExt`
[INFO] [stdout]              `std::sync::Mutex<tokio::net::TcpStream>: std::io::Write`
[INFO] [stdout]              which is required by `Arc<std::sync::Mutex<tokio::net::TcpStream>>: std::io::Write`
[INFO] [stdout]              `std::sync::Mutex<tokio::net::TcpStream>: AsyncWrite`
[INFO] [stdout]              which is required by `std::sync::Mutex<tokio::net::TcpStream>: AsyncWriteExt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0277]: the `?` operator can only be used in an async function that returns `Result` or `Option` (or another type that implements `FromResidual`)
[INFO] [stdout]     --> src/main.rs:1759:33
[INFO] [stdout]      |
[INFO] [stdout]  566 |   async fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,local_subscriptions: &mut HashSet<String>) -> Value {
[INFO] [stdout]      |  _______________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________-
[INFO] [stdout]  567 | |     let master_replid = "8371b4fb1155b71f4a04d3e1bc3e18c4a990aeeb";
[INFO] [stdout]  568 | |
[INFO] [stdout]  569 | |     let sub_registry_clone = Arc::clone(&sub_registry);
[INFO] [stdout] ...    |
[INFO] [stdout] 1759 | |         write_half.flush().await?;
[INFO] [stdout]      | |                                 ^ cannot use the `?` operator in an async function that returns `Value`
[INFO] [stdout] ...    |
[INFO] [stdout] 1771 | | }
[INFO] [stdout]      | |_- this function should return `Result` or `Option` to accept `?`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no variant, associated function, or constant named `Null` found for enum `Value` in the current scope
[INFO] [stdout]     --> src/main.rs:1765:12
[INFO] [stdout]      |
[INFO] [stdout] 1765 |     Value::Null
[INFO] [stdout]      |            ^^^^ variant, associated function, or constant not found in `Value`
[INFO] [stdout]      |
[INFO] [stdout]     ::: src/resp.rs:8:1
[INFO] [stdout]      |
[INFO] [stdout]    8 | pub enum Value {
[INFO] [stdout]      | -------------- variant, associated function, or constant `Null` not found for this enum
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0277]: the `?` operator can only be used in an async function that returns `Result` or `Option` (or another type that implements `FromResidual`)
[INFO] [stdout]     --> src/main.rs:1759:33
[INFO] [stdout]      |
[INFO] [stdout]  566 |   async fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,local_subscriptions: &mut HashSet<String>) -> Value {
[INFO] [stdout]      |  _______________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________________-
[INFO] [stdout]  567 | |     let master_replid = "8371b4fb1155b71f4a04d3e1bc3e18c4a990aeeb";
[INFO] [stdout]  568 | |
[INFO] [stdout]  569 | |     let sub_registry_clone = Arc::clone(&sub_registry);
[INFO] [stdout] ...    |
[INFO] [stdout] 1759 | |         write_half.flush().await?;
[INFO] [stdout]      | |                                 ^ cannot use the `?` operator in an async function that returns `Value`
[INFO] [stdout] ...    |
[INFO] [stdout] 1771 | | }
[INFO] [stdout]      | |_- this function should return `Result` or `Option` to accept `?`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0599]: no variant, associated function, or constant named `Null` found for enum `Value` in the current scope
[INFO] [stdout]     --> src/main.rs:1765:12
[INFO] [stdout]      |
[INFO] [stdout] 1765 |     Value::Null
[INFO] [stdout]      |            ^^^^ variant, associated function, or constant not found in `Value`
[INFO] [stdout]      |
[INFO] [stdout]     ::: src/resp.rs:8:1
[INFO] [stdout]      |
[INFO] [stdout]    8 | pub enum Value {
[INFO] [stdout]      | -------------- variant, associated function, or constant `Null` not found for this enum
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0061]: this function takes 11 arguments but 9 arguments were supplied
[INFO] [stdout]     --> src/main.rs:1866:43
[INFO] [stdout]      |
[INFO] [stdout] 1866 | ... = execute_command(&q_cmd, q_args, &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config),Arc::clone(&active_aof_path)).aw...
[INFO] [stdout]      |       ^^^^^^^^^^^^^^^-------------------------------------------------------------------------------------------------------------------------------------------- two arguments of type `&Arc<std::sync::Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>>` and `&mut HashSet<String>` are missing
[INFO] [stdout]      |
[INFO] [stdout] note: function defined here
[INFO] [stdout]     --> src/main.rs:566:10
[INFO] [stdout]      |
[INFO] [stdout]  566 | ...fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,local_subscriptions: &mut HashSet<String>) -...
[INFO] [stdout]      |       ^^^^^^^^^^^^^^^                                                                                                                                                                                                                                       ------------------------------------------------------------------------------------------ -----------------------------------------
[INFO] [stdout] help: provide the arguments
[INFO] [stdout]      |
[INFO] [stdout] 1866 -                                 let res = execute_command(&q_cmd, q_args, &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config),Arc::clone(&active_aof_path)).await;
[INFO] [stdout] 1866 +                                 let res = execute_command(&q_cmd, q_args, &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config), Arc::clone(&active_aof_path), /* &Arc<Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>> */, /* &mut HashSet<String> */).await;
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0061]: this function takes 11 arguments but 9 arguments were supplied
[INFO] [stdout]     --> src/main.rs:1866:43
[INFO] [stdout]      |
[INFO] [stdout] 1866 | ... = execute_command(&q_cmd, q_args, &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config),Arc::clone(&active_aof_path)).aw...
[INFO] [stdout]      |       ^^^^^^^^^^^^^^^-------------------------------------------------------------------------------------------------------------------------------------------- two arguments of type `&Arc<std::sync::Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>>` and `&mut HashSet<String>` are missing
[INFO] [stdout]      |
[INFO] [stdout] note: function defined here
[INFO] [stdout]     --> src/main.rs:566:10
[INFO] [stdout]      |
[INFO] [stdout]  566 | ...fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,local_subscriptions: &mut HashSet<String>) -...
[INFO] [stdout]      |       ^^^^^^^^^^^^^^^                                                                                                                                                                                                                                       ------------------------------------------------------------------------------------------ -----------------------------------------
[INFO] [stdout] help: provide the arguments
[INFO] [stdout]      |
[INFO] [stdout] 1866 -                                 let res = execute_command(&q_cmd, q_args, &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config),Arc::clone(&active_aof_path)).await;
[INFO] [stdout] 1866 +                                 let res = execute_command(&q_cmd, q_args, &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config), Arc::clone(&active_aof_path), /* &Arc<Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>> */, /* &mut HashSet<String> */).await;
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]     --> src/main.rs:1907:180
[INFO] [stdout]      |
[INFO] [stdout] 1907 | ...=> execute_command(c, args.clone(), &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config), Arc::clone(&active_aof_path), Arc::clone(&sub_registry), &...
[INFO] [stdout]      |       --------------- arguments to this function are incorrect                                                                                                      ^^^^^^^^^^^^^^^^^^^^^^^^^ expected `&Arc<Mutex<HashMap<String, Vec<_>>>>`, found `Arc<Mutex<HashMap<String, Vec<_>>>>`
[INFO] [stdout]      |
[INFO] [stdout]      = note: expected reference `&Arc<_>`
[INFO] [stdout]                    found struct `Arc<_>`
[INFO] [stdout] note: function defined here
[INFO] [stdout]     --> src/main.rs:566:10
[INFO] [stdout]      |
[INFO] [stdout]  566 | ...fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,lo...
[INFO] [stdout]      |       ^^^^^^^^^^^^^^^                                                                                                                                                                                                                                       ------------------------------------------------------------------------------------------
[INFO] [stdout] help: consider borrowing here
[INFO] [stdout]      |
[INFO] [stdout] 1907 |                 c => execute_command(c, args.clone(), &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config), Arc::clone(&active_aof_path), &Arc::clone(&sub_registry), &mut local_subscriptions).await,
[INFO] [stdout]      |                                                                                                                                                                                    +
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]     --> src/main.rs:1907:180
[INFO] [stdout]      |
[INFO] [stdout] 1907 | ...=> execute_command(c, args.clone(), &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config), Arc::clone(&active_aof_path), Arc::clone(&sub_registry), &...
[INFO] [stdout]      |       --------------- arguments to this function are incorrect                                                                                                      ^^^^^^^^^^^^^^^^^^^^^^^^^ expected `&Arc<Mutex<HashMap<String, Vec<_>>>>`, found `Arc<Mutex<HashMap<String, Vec<_>>>>`
[INFO] [stdout]      |
[INFO] [stdout]      = note: expected reference `&Arc<_>`
[INFO] [stdout]                    found struct `Arc<_>`
[INFO] [stdout] note: function defined here
[INFO] [stdout]     --> src/main.rs:566:10
[INFO] [stdout]      |
[INFO] [stdout]  566 | ...fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,lo...
[INFO] [stdout]      |       ^^^^^^^^^^^^^^^                                                                                                                                                                                                                                       ------------------------------------------------------------------------------------------
[INFO] [stdout] help: consider borrowing here
[INFO] [stdout]      |
[INFO] [stdout] 1907 |                 c => execute_command(c, args.clone(), &db, is_replica, &replicas, &write_half, Arc::clone(&master_repl_offset), Arc::clone(&config), Arc::clone(&active_aof_path), &Arc::clone(&sub_registry), &mut local_subscriptions).await,
[INFO] [stdout]      |                                                                                                                                                                                    +
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]    --> src/main.rs:401:55
[INFO] [stdout]     |
[INFO] [stdout] 392 | ...                   execute_command(
[INFO] [stdout]     |                       --------------- arguments to this function are incorrect
[INFO] [stdout] ...
[INFO] [stdout] 401 | ...                       Arc::new(None, ), Arc::clone(&sub_registry), &mut HashSet::new()
[INFO] [stdout]     |                                             ^^^^^^^^^^^^^^^^^^^^^^^^^ expected `&Arc<Mutex<HashMap<String, Vec<_>>>>`, found `Arc<Mutex<HashMap<_, _>>>`
[INFO] [stdout]     |
[INFO] [stdout]     = note: expected reference `&Arc<Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>>`
[INFO] [stdout]                   found struct `Arc<Mutex<HashMap<_, _>>>`
[INFO] [stdout] note: function defined here
[INFO] [stdout]    --> src/main.rs:566:10
[INFO] [stdout]     |
[INFO] [stdout] 566 | ...fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,lo...
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^                                                                                                                                                                                                                                       ------------------------------------------------------------------------------------------
[INFO] [stdout] help: consider borrowing here
[INFO] [stdout]     |
[INFO] [stdout] 401 |                                     Arc::new(None, ), &Arc::clone(&sub_registry), &mut HashSet::new()
[INFO] [stdout]     |                                                       +
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]    --> src/main.rs:401:55
[INFO] [stdout]     |
[INFO] [stdout] 392 | ...                   execute_command(
[INFO] [stdout]     |                       --------------- arguments to this function are incorrect
[INFO] [stdout] ...
[INFO] [stdout] 401 | ...                       Arc::new(None, ), Arc::clone(&sub_registry), &mut HashSet::new()
[INFO] [stdout]     |                                             ^^^^^^^^^^^^^^^^^^^^^^^^^ expected `&Arc<Mutex<HashMap<String, Vec<_>>>>`, found `Arc<Mutex<HashMap<_, _>>>`
[INFO] [stdout]     |
[INFO] [stdout]     = note: expected reference `&Arc<Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>>`
[INFO] [stdout]                   found struct `Arc<Mutex<HashMap<_, _>>>`
[INFO] [stdout] note: function defined here
[INFO] [stdout]    --> src/main.rs:566:10
[INFO] [stdout]     |
[INFO] [stdout] 566 | ...fn execute_command(command: &str, args: Vec<Value>, db: &Db, is_replica: bool, replicas: &ReplicaList, write_half: &Arc<std::sync::Mutex<TcpStream>>, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_regsitry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>,lo...
[INFO] [stdout]     |       ^^^^^^^^^^^^^^^                                                                                                                                                                                                                                       ------------------------------------------------------------------------------------------
[INFO] [stdout] help: consider borrowing here
[INFO] [stdout]     |
[INFO] [stdout] 401 |                                     Arc::new(None, ), &Arc::clone(&sub_registry), &mut HashSet::new()
[INFO] [stdout]     |                                                       +
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0061]: this function takes 9 arguments but 8 arguments were supplied
[INFO] [stdout]     --> src/main.rs:511:17
[INFO] [stdout]      |
[INFO] [stdout]  511 |                   handle_conn(
[INFO] [stdout]      |  _________________^^^^^^^^^^^-
[INFO] [stdout]  512 | |                     stream,
[INFO] [stdout]  513 | |                     db_master,
[INFO] [stdout]  514 | |                     true,
[INFO] [stdout] ...    |
[INFO] [stdout]  519 | |                     aof_master,
[INFO] [stdout]  520 | |                 )
[INFO] [stdout]      | |_________________- argument #9 of type `&Arc<std::sync::Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>>` is missing
[INFO] [stdout]      |
[INFO] [stdout] note: function defined here
[INFO] [stdout]     --> src/main.rs:1776:10
[INFO] [stdout]      |
[INFO] [stdout] 1776 | ...fn handle_conn(stream: TcpStream, db: Db, is_replica: bool, replicas: ReplicaList, is_master_connection: bool, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_registry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>) {
[INFO] [stdout]      |       ^^^^^^^^^^^                                                                                                                                                                                                    ------------------------------------------------------------------------------------------
[INFO] [stdout] help: provide the argument
[INFO] [stdout]      |
[INFO] [stdout]  511 |                 handle_conn(
[INFO] [stdout]  ...
[INFO] [stdout]  519 |                     aof_master,
[INFO] [stdout]  520 ~                     /* &Arc<Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>> */,
[INFO] [stdout]  521 ~                 )
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0061]: this function takes 9 arguments but 8 arguments were supplied
[INFO] [stdout]     --> src/main.rs:511:17
[INFO] [stdout]      |
[INFO] [stdout]  511 |                   handle_conn(
[INFO] [stdout]      |  _________________^^^^^^^^^^^-
[INFO] [stdout]  512 | |                     stream,
[INFO] [stdout]  513 | |                     db_master,
[INFO] [stdout]  514 | |                     true,
[INFO] [stdout] ...    |
[INFO] [stdout]  519 | |                     aof_master,
[INFO] [stdout]  520 | |                 )
[INFO] [stdout]      | |_________________- argument #9 of type `&Arc<std::sync::Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>>` is missing
[INFO] [stdout]      |
[INFO] [stdout] note: function defined here
[INFO] [stdout]     --> src/main.rs:1776:10
[INFO] [stdout]      |
[INFO] [stdout] 1776 | ...fn handle_conn(stream: TcpStream, db: Db, is_replica: bool, replicas: ReplicaList, is_master_connection: bool, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_registry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>) {
[INFO] [stdout]      |       ^^^^^^^^^^^                                                                                                                                                                                                    ------------------------------------------------------------------------------------------
[INFO] [stdout] help: provide the argument
[INFO] [stdout]      |
[INFO] [stdout]  511 |                 handle_conn(
[INFO] [stdout]  ...
[INFO] [stdout]  519 |                     aof_master,
[INFO] [stdout]  520 ~                     /* &Arc<Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>> */,
[INFO] [stdout]  521 ~                 )
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0061]: this function takes 9 arguments but 8 arguments were supplied
[INFO] [stdout]     --> src/main.rs:544:21
[INFO] [stdout]      |
[INFO] [stdout]  544 |                       handle_conn(
[INFO] [stdout]      |  _____________________^^^^^^^^^^^-
[INFO] [stdout]  545 | |                         stream,
[INFO] [stdout]  546 | |                         db_client,
[INFO] [stdout]  547 | |                         is_replica,
[INFO] [stdout] ...    |
[INFO] [stdout]  552 | |                         aof_path_clone,
[INFO] [stdout]  553 | |                     )
[INFO] [stdout]      | |_____________________- argument #9 of type `&Arc<std::sync::Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>>` is missing
[INFO] [stdout]      |
[INFO] [stdout] note: function defined here
[INFO] [stdout]     --> src/main.rs:1776:10
[INFO] [stdout]      |
[INFO] [stdout] 1776 | ...fn handle_conn(stream: TcpStream, db: Db, is_replica: bool, replicas: ReplicaList, is_master_connection: bool, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_registry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>) {
[INFO] [stdout]      |       ^^^^^^^^^^^                                                                                                                                                                                                    ------------------------------------------------------------------------------------------
[INFO] [stdout] help: provide the argument
[INFO] [stdout]      |
[INFO] [stdout]  544 |                     handle_conn(
[INFO] [stdout]  ...
[INFO] [stdout]  552 |                         aof_path_clone,
[INFO] [stdout]  553 ~                         /* &Arc<Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>> */,
[INFO] [stdout]  554 ~                     )
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] error[E0061]: this function takes 9 arguments but 8 arguments were supplied
[INFO] [stdout]     --> src/main.rs:544:21
[INFO] [stdout]      |
[INFO] [stdout]  544 |                       handle_conn(
[INFO] [stdout]      |  _____________________^^^^^^^^^^^-
[INFO] [stdout]  545 | |                         stream,
[INFO] [stdout]  546 | |                         db_client,
[INFO] [stdout]  547 | |                         is_replica,
[INFO] [stdout] ...    |
[INFO] [stdout]  552 | |                         aof_path_clone,
[INFO] [stdout]  553 | |                     )
[INFO] [stdout]      | |_____________________- argument #9 of type `&Arc<std::sync::Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>>` is missing
[INFO] [stdout]      |
[INFO] [stdout] note: function defined here
[INFO] [stdout]     --> src/main.rs:1776:10
[INFO] [stdout]      |
[INFO] [stdout] 1776 | ...fn handle_conn(stream: TcpStream, db: Db, is_replica: bool, replicas: ReplicaList, is_master_connection: bool, master_repl_offset: Arc<Mutex<usize>>, config: Arc<Config>, active_aof_path: Arc<Option<PathBuf>>, sub_registry: &Arc<Mutex<HashMap<String, Vec<tokio::sync::mpsc::UnboundedSender<Value>>>>>) {
[INFO] [stdout]      |       ^^^^^^^^^^^                                                                                                                                                                                                    ------------------------------------------------------------------------------------------
[INFO] [stdout] help: provide the argument
[INFO] [stdout]      |
[INFO] [stdout]  544 |                     handle_conn(
[INFO] [stdout]  ...
[INFO] [stdout]  552 |                         aof_path_clone,
[INFO] [stdout]  553 ~                         /* &Arc<Mutex<HashMap<String, Vec<UnboundedSender<Value>>>>> */,
[INFO] [stdout]  554 ~                     )
[INFO] [stdout]      |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0061, E0277, E0308, E0425, E0599.
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0061, E0277, E0308, E0425, E0599.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0061`.
[INFO] [stdout] 
[INFO] [stdout] For more information about an error, try `rustc --explain E0061`.
[INFO] [stdout] 
[INFO] [stderr] error: could not compile `redis-clone` (bin "redis-clone" test) due to 15 previous errors; 12 warnings emitted
[INFO] [stderr] warning: build failed, waiting for other jobs to finish...
[INFO] [stderr] error: could not compile `redis-clone` (bin "redis-clone") due to 15 previous errors; 12 warnings emitted
[INFO] running `Command { std: "docker" "inspect" "a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2", kill_on_drop: false }`
[INFO] [stdout] a58f1dc61326313d8fed3179e20c26978d0466b93720f7641d9466000f97d6a2
